示例说明

新建产品（MQTT）和设备

1. 新建产品

   • 登录物联网平台，通过 设备管理>产品管理>添加产品 创建产品。示例均使用MQTT协议。

     

2. 添加属性

   • 通过 设备管理>产品管理>详情>添加自定义功能 添加属性。说明： 属性名称最好设为英文，否则任务运行的时候会出现字段重名的错误。

     

3. 添加设备

   • 通过 设备管理>产品管理>设备管理>添加设备 添加设备

     

数据源配置

• 创建数据源
• 创建输出表和维表：使用任意的数据库连接工具连接到数据库，根据需要使用数据库的建表语法，即可创建相应的表。
• 查看数据：使用任意的数据库连接工具连接到数据库，查看输出表最新的数据

设备上报数据

数据上报可以是真实设备上报的数据，也可以是模拟设备上报的数据。为了方便调试，介绍的示例均使用脚本模拟设备上报数据。

脚本使用方法：

./sample_data.sh productId deviceId '{"temperature":10}'

其中productId为上报数据的产品ID，deviceId为上报数据的设备ID，最后一个参数为需要上报的属性名称和值的json字符串。

简单示例

我们将会从下面4个使用场景来讲述流数据分析的能力及使用方法：

1. 高温告警
2. 温度平均值计算
3. 订单结算
4. 连续高温报警

复杂任务构建

上述的例子均为简单例子，除了输入和输出只有一个组件。可以通过引入更多的组件构建出复杂的任务，实现更为复杂的流计算功能。下面介绍一个复杂的例子：

1. 发电机转速监测和异常情况报警